const request = require('request');

// 获取设备是否在线数据
exports.getstatus = (req, res) => {
  const user = req.body
  const url = 'https://apis.bemfa.com/va/online/?' + 'uid=' + user.uid + '&topic=' + user.topic + '&type=' + user.type
  request(url, function (err, response, body) {
    console.log(err, response, body);
    //err 当前接口请求错误信息
    //response 一般使用statusCode来获取接口的http的执行状态
    //body 当前接口response返回的具体数据 返回的是一个jsonString类型的数据 
    //需要通过JSON.parse(body)来转换
    if (!err && response.statusCode == 200) {
      //todoJSON.parse(body)
      var list = JSON.parse(body);
      // console.log(res1);
      res.send({ status: 200, message: '获取成功', list })
    } else {
      res.send({ err })
    }
  })
}
// 获取传感器数据
exports.getdata = (req, res) => {
  const user = req.body
  const url = 'https://api.bemfa.com/api/device/v1/data/3/get/?' + 'uid=' + user.uid + '&topic=' + user.topic + '&num=' + user.num
  request(url, function (err, response, body) {
    //err 当前接口请求错误信息
    //response 一般使用statusCode来获取接口的http的执行状态
    //body 当前接口response返回的具体数据 返回的是一个jsonString类型的数据 
    //需要通过JSON.parse(body)来转换
    if (!err && response.statusCode == 200) {
      //todoJSON.parse(body)
      var list = JSON.parse(body);
      // console.log(res1);
      res.send({ status: 200, message: '获取成功', list })
    } else {
      res.send({ err })
    }
  })
}
exports.postdata = (req, res) => {
  const user = req.body
  request({
    method: 'post',
    url: 'https://api.bemfa.com/api/device/v1/data/3/push/post/',
    headers: {
      "content-type": "application/x-www-form-urlencoded",
    },
    form: user
  }, function (err, response, body) {
    //err 当前接口请求错误信息
    //response 一般使用statusCode来获取接口的http的执行状态
    //body 当前接口response返回的具体数据 返回的是一个jsonString类型的数据 
    //需要通过JSON.parse(body)来转换
    if (!err && response.statusCode == 200) {
      res.send({ status: 200, message: '请求成功' })
    } else {
      res.send({ err })
    }
  })
}
